package com.king.bean

import lombok.Data

import scala.beans.BeanProperty

/**
 * @Author: KingWang
 * @Date: 2022/1/10  
 * @Desc:
 **/
class TableProcess extends Serializable {

  //动态分流sink常量
   val SINK_TYPE_HBASE="hbase"
   val SINK_TYPE_KAFKA="kafka"
   val SINK_TYPE_CK="clickhouse"

  //来源表
  @BeanProperty  var sourceTable:String = _
  //操作类型：insert,update,delete
  @BeanProperty  var operateType:String = _
  //输出类型 hbase kafka
  @BeanProperty  var sinkType:String = _
  //输出表(主题)
  @BeanProperty var sinkTable:String = _
  //输出字段
  @BeanProperty  var sinkColumns:String = _
  //主键字段
  @BeanProperty  var sinkPk:String = _
  //扩展属性
  @BeanProperty  var sinkExtend:String = _
}
